package org.niit.app

import org.apache.spark.SparkConf
import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.AdClickData
import org.niit.common.TApp
 import org.niit.handler.DataHandler

// ps：该案例执行步骤：删除对应Kafka主题和建立数据库的表 --> 运行app代码 --> 运行mock代码（模拟数据）

// 直接去获取数据的代码 以及 调用 Controller代码
object AdRealTimeApp extends App with TApp{

  start(appName = "AdRealTimeApp"){  // 继承TApp


    val value: DStream[AdClickData] = DataHandler.KafkaDataHandler("BD1", "newAD1")  // 获取Kafka的数据，实时的数据分析


    val mapDS = value.map((_, 1))
    mapDS.print()

    DataHandler.startAndAwait()

  }

}